//package com.culturalCenter.dataCenter.SparkOnHbaseTest;
//
//import com.culturalCenter.dataCenter.globalconfig.hbasee.HbaseTemplate;
//import org.apache.hadoop.conf.Configuration;
//import org.apache.hadoop.hbase.Cell;
//import org.apache.hadoop.hbase.CellUtil;
//import org.apache.hadoop.hbase.HBaseConfiguration;
//import org.apache.hadoop.hbase.client.Result;
//import org.apache.hadoop.hbase.io.ImmutableBytesWritable;
//import org.apache.hadoop.hbase.mapreduce.TableInputFormat;
//import org.apache.hadoop.hbase.util.Bytes;
//import org.apache.spark.api.java.JavaPairRDD;
//import org.apache.spark.api.java.JavaSparkContext;
//import org.apache.spark.sql.SparkSession;
//import org.springframework.stereotype.Component;
//
//import javax.annotation.Resource;
//import java.util.List;
//
///**
// * 可以不序化使用
// */
//@Component
//@Slf4j
//public class HbaseGetData {
//
//    @Resource
//    private HbaseTemplate hbaseTemplate;
//
//    @Resource
//    private JavaSparkContext sc;
//
//    /**
//     * 可以成功获取数据
//     **/
//    public void getData_1() {
//
//        String tableName = "users";
//        String FAMILY = "personal";
//        String COLUM_ID = "id";
//        String COLUM_NAME = "name";
//        String COLUM_PHONE = "phone";
//
//        // //初始化SparkSession对象
////                SparkSession spark = SparkSession.builder().config(sc.getConf()).getOrCreate();
//
//        // Hbase配置
//        Configuration hconf = HBaseConfiguration.create();
//        hconf.set(TableInputFormat.INPUT_TABLE, tableName);
//
//        hconf.set(TableInputFormat.SCAN_COLUMNS, "personal:name personal:phone personal:id");
//        try {
//            sc.getConf().setAppName("test");
//            //读HBase数据转化成RDD
//            JavaPairRDD<ImmutableBytesWritable, Result> hbaseRDD = sc.newAPIHadoopRDD(hconf, TableInputFormat.class, ImmutableBytesWritable.class, Result.class);
//            hbaseRDD.cache();// 对myRDD进行缓存
//            long count = hbaseRDD.count();
//
//            List<Result> list = hbaseRDD.map(t -> t._2()).collect();
//            for (Result result : list) {
//                List<Cell> cells = result.listCells();
//                for (Cell cell : cells) {
//                }
//            }
//        } catch (Exception e) {
//            log.error(e.getMessage(), e);
//        } finally {
//        }
//    }
//}
